8b3f158a436fcbbcf2e6ed9dc422120a23a01929,broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java,Qos1PublishHandler,receivedPublishQos1,#Channel#PublishMessage#,44

Before Change


        String clientID = NettyUtils.clientID(channel);
        toStoreMsg.setClientID(clientID);

        LOG.debug("publish2Subscribers_qos1 republishing to existing subscribers that matches the topic {}", topic);
        if (LOG.isTraceEnabled()) {
            LOG.trace("content <{}>", DebugUtils.payload2Str(toStoreMsg.getMessage()));
            LOG.trace("subscription tree {}", subscriptions.dumpTree());
        }
        List<Subscription> topicMatchingSubscriptions = subscriptions.matches(topic);
        this.publisher.publish2Subscribers(toStoreMsg, topicMatchingSubscriptions);

After Change


        String clientID = NettyUtils.clientID(channel);
        toStoreMsg.setClientID(clientID);

		if (LOG.isDebugEnabled()) {
			LOG.debug("Sending publish message to subscribers. MqttClientId = {}, topic = {}, messageId = {}, payload = {}, subscriptionTree = {}.",
					clientID, topic, msg.getMessageID(), DebugUtils.payload2Str(toStoreMsg.getMessage()),
					subscriptions.dumpTree());
		} else {
			LOG.info("Sending publish message to subscribers. MqttClientId = {}, topic = {}, messageId = {}.", clientID,
					topic, msg.getMessageID());
		}

        List<Subscription> topicMatchingSubscriptions = subscriptions.matches(topic);